package com.test.sink;

import lombok.extern.slf4j.Slf4j;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

@Slf4j
public class FraudSink<IN> extends RichSinkFunction<String> {


    @Override
    public void invoke(String value, Context context) throws Exception {
        log.warn( "帐号 {} 存在安全隐患",value);
    }
}
